How to handle exceptions in Confluent-Kafka for python